package connection;

import java.util.Vector;

public class Relay {
	private Vector<SensorMessage> sensorMsgs;
	private Vector<ControllerMessage> controllerMsgs;
	
	public Relay() {
		sensorMsgs = new Vector<SensorMessage>();
		controllerMsgs = new Vector<ControllerMessage>();
	}
	
	public synchronized void addSensorMessage(SensorMessage msg) {
		sensorMsgs.add(msg);
	}
	
	public synchronized SensorMessage getSensorMessage() {
		if (!sensorMsgs.isEmpty()) {
			SensorMessage msg = sensorMsgs.firstElement();
			sensorMsgs.remove(msg);
			return msg;
		}
		return null;
	}
	
	public synchronized void addControllerMessage(ControllerMessage msg) {
		controllerMsgs.add(msg);
	}
	
	public synchronized ControllerMessage getControllerMessage() {
		if (!controllerMsgs.isEmpty()) {
			ControllerMessage msg = controllerMsgs.firstElement();
			controllerMsgs.remove(msg);
			return msg;
		}
		return null;
	}
}
